<?php
namespace app\api\controller;

use app\model\Items;

class ItemsController extends BaseController
{
    public function _initialize()
    {
        parent::_initialize();
    }

    public function create(){
        if($this->request->isPost()){
            $arr = [];
            $items_data = $this->request->post('data');
            if(is_jsonstr($items_data)){
                return json(msgReturn(false,'不是json格式'));
            }
            $arr=json_decode(htmlspecialchars_decode($items_data),true);
            if(empty($arr)){
                return json(msgReturn(true,'缺少参数',$arr));
            }

            $item = new Items();

            $data_map = [];
            foreach ($arr as $key => $val) {
                if($item->where(['item_id'=> $val['item_id']])->count()){
                    try{
                        $item->where(['item_id'=> $val['item_id']])->save($val);
                    }catch (\Exception $e){
                        echo print_r('商品中包括更新，但是操作失败。错误：'.$e->getMessage());
                    }
                }else{
                    $data_map[] = $val;
                }
            }

            if(!empty($data_map) && count($data_map) > 0){
                $res = $item->saveAll($data_map);
                if($res){
                    return json(msgReturn(true,'商品插入成功'));
                }else{
                    return json(msgReturn(true,'商品插入失败',$item->getError()));
                }
            }else{
                return json(msgReturn(true,'商品插入成功'));
            }
        }else{
            return json(msgReturn(false,'错误, 不支持的请求类型'));
        }
    }

    public function delete(){
        if($this->request->isPost()){
            $item = new Items();
            $val = $this->request->post('item_id');
            if($item->where(['item_id'=> $val])->count()){
                try{
                    $item->where(['item_id'=> $val])->delete();
                    return json(msgReturn(true,'success'));
                }catch (\Exception $e){
                    echo print_r('商品删除失败。错误：'.$e->getMessage());
                }
            }else{
                return json(msgReturn(false,'错误, 商品不存在'));
            }
        }else{
            return json(msgReturn(false,'错误, 不支持的请求类型'));
        }
    }

}